package org.yonggan.cmcc.report.RealTimeReportDateChain.function

import org.apache.spark.rdd.RDD
import org.yonggan.cmcc.report.RealTimeReportDateChain.RealTimeRechargeHandlerStart

object HandlerFuntions {

  /**
    * 将RDD 处理成 业务处理链
    *
    * @param rdd
    */
  implicit def rdd2RealTimeRechargeHandlerStart(rdd: RDD[(List[Double],String,String,String,String)]): RealTimeRechargeHandlerStart = new RealTimeRechargeHandlerStart(rdd)

}
